package com.gengzp.mq.client.constants;

/**
 * @ClassName MqTimeoutConstants
 * @Description 消息队列请求超时常量池
 * @Author gengzp
 * @Date 2025/9/4 17:25
 */
public interface MqTimeoutConstants {

    // 获取消息请求连接超时时间 (秒)
    long GET_MESSAGE_CONNECT_TIMEOUT = 35;

    // 订阅 topic 后, 未获取到消息的等待时间 (毫秒)
    long SUBSCRIBE_TOPIC_WAIT_TIMEOUT = 15000;

    // 消息ack确认失败, 重新确认等待时间 (毫秒)
    long ACK_MESSAGE_CONNECT_TIMEOUT = 5000;

}
